# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash_operator import BashOperator

jms_dim__dim_network_whole_massage = BashOperator(
    pool='unlimited_pool',
    task_id="jms_dim__dim_network_whole_massage",
    bash_command='jms_point_hi/dim/dim_network_whole_massage/execute.sh',
    execution_timeout=timedelta(minutes=30),
    #邮箱更换
    email=['wangmengelei@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=2,
)
